package com.xmx.productcenter.config;

import lombok.extern.slf4j.Slf4j;
import org.springframework.amqp.core.*;

import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.annotation.PostConstruct;

import static com.xmx.common.rabbitDto.OrderDto.*;

//@Configuration
@Slf4j
public class RabbitConfig {
//    @Bean
//    MessageConverter messageConverter() {
//        return new Jackson2JsonMessageConverter();
//    }
//
//    public static class StockForOrderConfig {
//
//
//        /**
//         * 创建交换机
//         */
//        @Bean
//        TopicExchange topicExchange() {
//
//            return new TopicExchange(STOCK_EVENT_EXCHANG, true, false);
//        }
//
//        /**
//         * 创建队列---普通队列（relese）、ttl队列（lock）
//         */
//
//        @Bean
//        Queue delayQueue() {
//
//            return QueueBuilder.durable(St) // durable: 是否持久化
//                    .ttl(6*1000) // 设置队列里的默认过期时间为 60 秒
//                    .deadLetterExchange(STOCK_EVENT_EXCHANG)
//                    .deadLetterRoutingKey(STOCK_RELESE_ROUTING)
//                    .build();
//        }
//
//        @Bean
//        Queue releseQueue(){
//            return new Queue(STOCK_RELESE_QUEUE,true,false,false);
//        }
//
//        /**
//         * 绑定
//         */
//        @Bean
//        public Binding releseBinding() {
//            return BindingBuilder.bind(releseQueue()).to(topicExchange()).with(STOCK_RELESE_ROUTING);
//        }
//        @Bean
//        public Binding delayBinding() {
////            new Binding()
//            return BindingBuilder.bind(delayQueue()).to(topicExchange()).with(STOCK_DELAY_ROUTING);
//        }
//
//    }
}

